package com.supplychain.scm.core.rocketmq.constant;

import com.supplychain.scm.core.rocketmq.bean.MessageTypeEnum;
import com.google.common.collect.Sets;

import java.util.Set;

/**
 * @author liyang
 * @version 1.0.0
 * @ClassName RocketMqConstant
 * @Description 常量
 * @createTime 11:07:00 2022/12/06
 */
public interface RocketMqConstant {

    Set<String> EXCLUDE_TOPICS = Sets.newHashSet("SUPPLY-CHAIN-ADMIN-TOPIC");

    Set<String> EXCLUDE_TAGS = Sets.newHashSet("SUPPLY-SYSTEM-LOG-TAG");

    String FORMAT = "%s:%s";

    String EXECUTOR_NAME = "ROCKET-POOL";
    /**
     * 消息链路ID Key
     */
    String MESSAGE_LINK_ID = "LINK_ID";
    /**
     * 失败
     */
    String FAIL = "FAIL";
    /**
     * 发送中
     */
    String SENDING = "SENDING";
    /**
     * 重试取消
     */
    String RETRY_CANCEL = "RETRY_CANCEL";
    /**
     * 成功
     */
    String SUCCESS = "SUCCESS";
    /**
     * keys
     */
    String KEYS = "KEYS";
    /**
     * 消息类型
     * @see MessageTypeEnum
     */
    String MESSAGE_TYPE = "TYPE";
    /**
     * 消息来源
     */
    String MESSAGE_ORIGIN = "ORIGIN";
}
